# -*- coding: utf-8 -*-
# ㊎ Author : XMZ
# ㊍ Time : 2021/5/3 15:31
# ㊌ File : RabbitMQ -> producer_a.py
# ㊋ IDE :  PyCharm
# ㊏ 
import os
import sys
import time

import pika

self_path = os.path.dirname(os.path.abspath(__file__))
father_path = os.path.dirname(self_path)
parent_path = os.path.dirname(father_path)
sys.path.append(self_path)
sys.path.append(father_path)
sys.path.append(parent_path)

hosts = "10.0.2.22"
name = "admin"
pwd = "123456"
credential = pika.PlainCredentials(username=name, password=pwd)
connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        host=hosts,
        credentials=credential,
        heartbeat=0,
    ))
queue_name = "TEST_QUEUE"
channel = connection.channel()
channel.queue_declare(queue=queue_name, durable=True)
for i in [
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
    'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb', 'a', 'bbbb',
]:
    # time.sleep(0.5)
    channel.basic_publish(exchange="",
                          routing_key=queue_name,
                          body=f"{i}",
                          #
                          )
connection.close()
